var mysql = require('mysql')
var dbConfig = require('./db.config')
module.exports = {
    query: function(sql, params, callback) {
        //每次使⽤的时候需要创建链接，数据操作完成之后要关闭连接
        var connection = mysql.createConnection(dbConfig)
        connection.connect(function(err) {
            if (err) {
                throw err
            }
            //开始数据操作
            connection.query(sql, params, function(err, results) {

                // connection.query(sql, params, function(err, results, fields) {  fields返回undefined的时候程序会终止 所以暂时取消该参数

                if (err) {
                    throw err
                }
                //将查询出来的数据返回给回调函数
                callback &&
                    callback(
                        JSON.parse(JSON.stringify(results)),
                        // JSON.parse(JSON.stringify(fields))
                    )
                    //停⽌链接数据库，必须在查询语句后，要不然⼀调⽤这个⽅法，就直接停⽌链接，数据操作就会失败
                connection.end(function(err) {
                    if (err) {
                        console.log('关闭数据库连接失败！')
                        throw err
                    }
                })
            })
        })
    },
}